Skip to content

[pull] master from apache:master - #639

Merged
pull[bot] merged 2 commits into
section9-lab:masterfrom
apache:master
Aug 28, 2026
Merged

[pull] master from apache:master#639
pull[bot] merged 2 commits into
section9-lab:masterfrom
apache:master

Conversation

@pull

@pull pull Bot commented Aug 28, 2026

Copy link
Copy Markdown

See Commits and Changes for more details.


Created by pull[bot] (v2.0.0-alpha.4)

Can you help keep this open source service alive? 💖 Please sponsor : )

Amar3tto and others added 2 commits August 27, 2026 21:48
Prepares the structured streaming runner for a Spark 4 streaming
translator without changing batch behavior.

- Add PipelineTranslatorFactory, the seam the Spark 4 module shadows to
  dispatch streaming pipelines. The shared base rejects streaming with a
  clear message instead of the previous generic checkArgument.
- Open up EvaluationContext (non final, protected ctor, leaves()) and add
  a no-op stop() so a streaming context can override evaluation.
- Add a createEvaluationContext hook to PipelineTranslator and skip the
  persist and lineage breaking optimizations for streaming datasets.
- Plumb the EvaluationContext into SparkStructuredStreamingPipelineResult
  so cancel() can stop a running streaming query.
- Default the state store provider to RocksDB, required by Spark 4
  transformWithState and inert for batch.
- Add watermarkDelayMillis, maxRecordsPerMicroBatch, maxBatchDurationMillis
  and streamingStopAfterIdleBatches options.
- Narrow the Spark 4 test source override exclude to the legacy DStream
  package. The previous glob also matched structuredstreaming and would
  have silently dropped the structured streaming tests.
@pull pull Bot locked and limited conversation to collaborators Aug 28, 2026
@pull pull Bot added the ⤵️ pull label Aug 28, 2026
@pull
pull Bot merged commit d7557af into section9-lab:master Aug 28, 2026
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants